google.golang.org/grpc/internal/transport.http2Client.closeStream (method)
15 uses
google.golang.org/grpc/internal/transport (current package)
client_stream.go#L72: s.ct.closeStream(s, err, rst, rstCode, status.Convert(err), nil, false)
http2_client.go#L927: func (t *http2Client) closeStream(s *ClientStream, err error, rst bool, rstCode http2.ErrCode, st *status.Status, mdata map[string][]string, eosReceived bool) {
http2_client.go#L1052: t.closeStream(s, err, false, http2.ErrCodeNo, st, nil, false)
http2_client.go#L1210: t.closeStream(s, io.EOF, true, http2.ErrCodeFlowControl, status.New(codes.Internal, err.Error()), nil, false)
http2_client.go#L1234: t.closeStream(s, io.EOF, false, http2.ErrCodeNo, status.New(codes.Internal, "server closed the stream without sending trailers"), nil, true)
http2_client.go#L1262: t.closeStream(s, st.Err(), false, http2.ErrCodeNo, st, nil, false)
http2_client.go#L1399: t.closeStream(stream, errStreamDrain, false, http2.ErrCodeNo, statusGoAway, nil, false)
http2_client.go#L1448: t.closeStream(s, st.Err(), true, http2.ErrCodeProtocol, st, nil, false)
http2_client.go#L1456: t.closeStream(s, se.Err(), true, http2.ErrCodeFrameSize, se, nil, endStream)
http2_client.go#L1495: t.closeStream(s, se.Err(), true, http2.ErrCodeProtocol, se, nil, endStream)
http2_client.go#L1512: t.closeStream(s, se.Err(), true, http2.ErrCodeProtocol, se, nil, endStream)
http2_client.go#L1556: t.closeStream(s, se.Err(), true, http2.ErrCodeProtocol, se, nil, endStream)
http2_client.go#L1562: t.closeStream(s, se.Err(), true, http2.ErrCodeProtocol, se, nil, endStream)
http2_client.go#L1614: t.closeStream(s, io.EOF, rstStream, http2.ErrCodeNo, status, mdata, true)
http2_client.go#L1678: t.closeStream(s, status.Error(code, msg), true, http2.ErrCodeProtocol, status.New(code, msg), nil, false)